b2dccea2bb5fedc66cbfbbc26b06b9df2f9ae351,data-fabric/src/main/java/com/continuuity/data2/transaction/queue/hbase/coprocessor/DequeueScanObserver.java,DequeueScanObserver,preScannerOpen,#ObserverContext#Scan#RegionScanner#,52
Before Change
Filter existing = scan.getFilter();
Filter combined = new FilterList(FilterList.Operator.MUST_PASS_ALL, existing, dequeueFilter);
scan.setFilter(combined);
return super.preScannerOpen(e, scan, s);
}
After Change
Filter dequeueFilter = new DequeueFilter(queueName, consumerConfig, tx);
Filter existing = scan.getFilter();
if (existing != null) {
Filter combined = new FilterList(FilterList.Operator.MUST_PASS_ALL, existing, dequeueFilter);
scan.setFilter(combined);
} else {
scan.setFilter(dequeueFilter);
}